import os

from django.utils import timezone
from celery import Celery
# from celery.schedules import crontab, timedelta

from celery_tasks import config

# 设置环境变量, 导入django配置; 后续便于使用django组件功能
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'dashboard.settings')

app = Celery("apps")

# 读取配置文件中的配置
app.config_from_object(config)

# 自动从django注册的app中发现所有任务
app.autodiscover_tasks()

# 解决时区问题,定时任务启动就循环输出
app.now = timezone.now

# celery -A dashboard worker -l info -P eventlet